# -*- coding: utf-8 -*-
from datetime import timedelta
from airflow.operators.bash_operator import BashOperator

jms_dwd__check_dwd_yl_oms_oms_waybill_last_hour_status = BashOperator(
    pool='unlimited_pool',
    task_id="jms_dwd__check_dwd_yl_oms_oms_waybill_last_hour_status",
    bash_command='jms_hi/dm/sqs_report/check_dwd_yl_oms_oms_waybill_last_hour_status/execute.sh',
    execution_timeout=timedelta(minutes=60),
    # 邮箱更换
    email=['shenjiaming@jtexpress.com', 'yl_bigdata@yl-scm.com'],
    retries=2,
)
